package org.apache.rocketmq.proxy.processor.validator;

import org.apache.rocketmq.common.attribute.TopicMessageType;



public interface TopicMessageTypeValidator {
    /**
     * Will throw {@link org.apache.rocketmq.proxy.common.ProxyException} if validate failed.
     *
     * @param expectedType Target topic
     * @param actualType   Message's type
     */
    void validate(TopicMessageType expectedType, TopicMessageType actualType);
}